package app.dwd;

/**
 * @Author 吴泽胜
 * @Date 2022/3/20 1:15
 * @Software IntelliJ IDEA
 * @Describe
 */
//数据流：web/app -> Nginx -> SpringBoot -> Kafka(ods) -> FlinkApp -> Kafka(dwd)
//程  序：postman/Jmeter -> Nginx -> springboot -> Kafka(ZK)  -> BaseLoggerApp -> kafka
public class BaseLoggerApp {

    public static void main(String[] args) {
        //TODO 1.获取执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);
    }
}
